﻿using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;

/*
 * 所属层次：数据访问类组件 
 */

namespace TalentPools.DAL
{
    /// <summary>
    /// DBHelper类是专门提供SQL数据操作
    /// </summary>
    public static class DBHelper
    {
        //数据库连接字符串
        //private static string ConnectionString = "Data Source=.;Initial Cataog=TalentPool;Integrated Security=true";
        private static readonly string ConnectionString = ConfigurationManager.AppSettings["con"].ToString();
        #region 准备执行一个命令
        /// <summary>
        /// 准备执行一个命令
        /// </summary>
        /// <param name="cmd">SQL命令对象</param>
        /// <param name="conn">SQL连接</param>
        /// <param name="tran">SQL事务</param>
        /// <param name="commandType">命令类型（文本或者存储过程）</param>
        /// <param name="commandText">命令文本，即SQL语句</param>
        /// <param name="paras">执行命令的参数</param>
        private static void PrepareCommand(SqlCommand cmd, SqlConnection conn, SqlTransaction tran, CommandType commandType, string commandText, SqlParameter[] paras)
        {
            if (conn.State != ConnectionState.Open)//如果数据库连接没有打开
            {
                conn.Close();//关闭连接
                conn.Open();//打开连接
            }
            //设置SqlCommand参数
            cmd.Connection = conn;
            cmd.CommandText = commandText;
            if (tran != null)//事务
            {
                cmd.Transaction = tran;
            }
            cmd.CommandType = commandType;
            switch (cmd.CommandType)
            {
                case CommandType.StoredProcedure://存储过程
                    //获取存储过程的参数
                    SqlCommandBuilder.DeriveParameters(cmd);
                    //移除Return_Value参数
                    cmd.Parameters.RemoveAt(0);
                    //设置参数值
                    if (paras != null)
                    {
                        for (int i = 0; i < cmd.Parameters.Count; i++)
                        {
                            cmd.Parameters[i].Value = paras[i];
                        }
                    }
                    break;
                case CommandType.TableDirect:
                    break;
                case CommandType.Text://命令文本
                    cmd.Parameters.Clear();//清空命令参数
                    //如果参数不为空，添加参数
                    if (paras != null)
                    {
                        foreach (SqlParameter param in paras)
                        {
                            cmd.Parameters.Add(param);
                        }
                    }
                    break;
                default:
                    break;
            }

        }
        #endregion
        #region 执行SQL语句或者存储过程，返回影响的行数
        /// <summary>
        /// 执行SQL语句，返回影响的行数
        /// </summary>
        /// <param name="commandType">命令类型（文本）</param>
        /// <param name="commandText">SQL命令语句</param>
        /// <param name="paras">执行命令所用的参数的集合</param>
        /// <returns>执行命令所影响的行数</returns>
        public static int ExecuteNonQuery(CommandType commandType, string commandText, params SqlParameter[] paras)
        {
            SqlCommand cmd = new SqlCommand();
            using (SqlConnection conn = new SqlConnection(ConnectionString))
            {
                //调用准备执行命令这个方法:此处可以加入一个事务控制
                PrepareCommand(cmd, conn, null, commandType, commandText, paras);
                int val = cmd.ExecuteNonQuery();
                cmd.Parameters.Clear();
                return val;
            }
        }
        #endregion
        #region 使用现有的SQL事务执行一个sql命令,返回影响的行数
        /// <summary>
        ///使用现有的SQL事务执行一个sql命令
        /// </summary>
        /// <param name="transaction">一个现有的事务</param>
        /// <param name="commandType">命令类型(存储过程, 文本, 等等)</param>
        /// <param name="commandText">存储过程名称或者sql命令语句</param>
        /// <param name="paras">执行命令所用参数的集合</param>
        /// <returns>执行命令所影响的行数</returns>
        public static int ExecuteNonQuery(SqlConnection connection, SqlTransaction transaction, CommandType commandType, string commandText, params SqlParameter[] paras)
        {
            //这里不能关闭连接，因为事务还没有完成，此连接将一直为本次事务提供服务。
            //连接将在相关的DAL数据模块中创建，然后传入本方法，所以本类的连接字符串要为Public
            SqlCommand cmd = new SqlCommand();
            PrepareCommand(cmd, connection, transaction, commandType, commandText, paras);
            int val = cmd.ExecuteNonQuery();
            cmd.Parameters.Clear();
            return val;
        }
        #endregion
        #region 执行一个返回读取器的SQL命令
        /// <summary>
        /// 返回一个读取器
        /// </summary>
        /// <param name="commandType">命令类型（存储过程或文本等）</param>
        /// <param name="commandText">存储过程名称或者SQL命令语句</param>
        /// <param name="paras">执行命令所用的参数的集合</param>
        /// <returns>包含结果的读取器</returns>
        public static SqlDataReader ExecuteGetReader(CommandType commandType, string commandText, params SqlParameter[] paras)
        {
            //创建一个SqlCommand对象
            SqlCommand cmd = new SqlCommand();
            //创建一个SqlConnection对象
            SqlConnection conn = new SqlConnection(ConnectionString);
            try
            {
                //调用PrepareCommand方法，对SqlCommand对象设置参数
                PrepareCommand(cmd, conn, null, commandType, commandText, paras);
                //调用SqlCommand的ExecuteReader方法
                SqlDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
                //清除参数
                cmd.Parameters.Clear();
                return reader;
            }
            catch
            {
                //关闭连接，抛出异常
                conn.Close();
                throw;
            }
        }

        #endregion
        #region 执行一个命令并返回第一列
        /// <summary>
        /// 返回一个数据集的第一列
        /// </summary>
        /// <param name="commandType">命令类型（存储过程或者文本等）</param>
        /// <param name="commandText">存储过程名称或者Sql命令</param>
        /// <param name="paras">执行命令所用的参数的集合</param>
        /// <returns></returns>
        public static object ExecuteScalar(CommandType commandType, string commandText, params SqlParameter[] paras)
        {
            //实例化一个SqlCommand对象
            SqlCommand cmd = new SqlCommand();
            using (SqlConnection conn = new SqlConnection(ConnectionString))
            {
                PrepareCommand(cmd, conn, null, commandType, commandText, paras);
                object val = cmd.ExecuteScalar();
                cmd.Parameters.Clear();
                return val;
            }
        }
        #endregion
        #region 使用现有的SQL事务执行一个sql命令,返回第一列
        /// <summary>
        ///使用现有的SQL事务执行一个sql命令
        /// </summary>
        /// <param name="transaction">一个现有的事务</param>
        /// <param name="commandType">命令类型(存储过程, 文本, 等等)</param>
        /// <param name="commandText">存储过程名称或者sql命令语句</param>
        /// <param name="paras">执行命令所用参数的集合</param>
        /// <returns>执行命令所影响的行数</returns>
        public static object ExecuteScalar(SqlConnection connection, SqlTransaction transaction, CommandType commandType, string commandText, params SqlParameter[] paras)
        {
            //这里不能关闭连接，因为事务还没有完成，此连接将一直为本次事务提供服务。
            //连接将在相关的DAL数据模块中创建，然后传入本方法，所以本类的连接字符串要为Public
            SqlCommand cmd = new SqlCommand();
            PrepareCommand(cmd, connection, transaction, commandType, commandText, paras);
            object val = cmd.ExecuteScalar();
            cmd.Parameters.Clear();
            return val;
        }
        #endregion

        #region 执行SQL语句或者存储过程，返回DataSet数据集
        /// <summary>
        /// 执行SQL语句或者存储过程，返回DataSet
        /// </summary>
        /// <param name="commandType">命令类型</param>
        /// <param name="commandText">命令文本或者存储过程名称</param>
        /// <param name="paras">执行命令所用参数的集合</param>
        /// <returns>DataSet对象</returns>
        public static DataSet ExecuteDataSet(CommandType commandType, string commandText, params SqlParameter[] paras)
        {
            using (SqlConnection conn = new SqlConnection(ConnectionString))
            {
                SqlCommand cmd = new SqlCommand();//实例化一个SqlCommand对象
                PrepareCommand(cmd, conn, null, commandType, commandText, paras);
                using (SqlDataAdapter da = new SqlDataAdapter(cmd))
                {
                    DataSet ds = new DataSet();

                    da.Fill(ds);
                    return ds;
                }
            }
        }
        #endregion
    }
}
